package cn.tx.config;

/**
 * @author Mxb
 * @version 1.0
 * @date 2020/10/10 20:42
 */
//@Component
//public class ConfirmImpl implements RabbitTemplate.ConfirmCallback {
//    @Autowired
//    private RabbitTemplate rabbitTemplate;
//
//    @Autowired
//    private ConfirmImpl confirmImpl;
//
//    @PostConstruct
//    public void initRabbitTemplate(){
//        rabbitTemplate.setConfirmCallback(confirmImpl);
//    }
//    /**
//     * 消息到达交互机后，该方法会回调
//     * @param correlationData 相关的数据
//     * @param ack 交互机是否接收成功
//     * @param cause 如果没有接收成功，返回拒绝的原因
//     */
//    @Override
//    public void confirm(CorrelationData correlationData, boolean ack, String
//            cause) {
//        if(ack){
//            System.out.println("交换机接收消息成功");
//        }else{
//            System.out.println("交换机接收消息失败,失败原因:"+cause);
//        }
//    }
//}
